package net.xdclass.mq;

import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;
import net.xdclass.redis.core.stream.AbstractRedisStreamMessageListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
public class RedisMqSmsSendConsumer extends AbstractRedisStreamMessageListener<RedisMqSmsSendMessage> {
    @Override
    public void onMessage(RedisMqSmsSendMessage message) {
        log.info("短信发送成功，消息内容"+JSONUtil.toJsonStr(message));
    }
}
